﻿using iot.Jobs.Entity;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace iot.Jobs
{
   public static class GlobalQueue
    {
        public static BlockingCollection<PutKafkaData> Queue { get; } =
      new BlockingCollection<PutKafkaData>(new ConcurrentQueue<PutKafkaData>());
    }
}
